package cloud.xiguapi.ubas.config;

import cloud.xiguapi.ubas.common.FlinkEnvironment;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

/**
 * Flink配置类
 *
 * @author 大大大西西瓜皮🍉
 * date: 2021-5-16 下午 11:56
 * desc:
 */
@Configuration
public class FlinkConfiguration {

    @Bean("env")
    @Primary
    public StreamExecutionEnvironment env() {
        return FlinkEnvironment.defaultEnvironment();
    }
}
